package com.chencong.online.driver.ods;

import com.chencong.online.utils.KafkaUtil;

import java.io.IOException;

/**
 * @Author chencong
 * @Description 读取本地本地文件到kafka
 * @Date 6:21 下午 2021/12/19
 * @Param
 **/
public class OdsUserBehaviorToKafkaDriver {
    public static void main(String[] args) throws IOException {
        KafkaUtil.getWriteToKafka("user_behavior_log", "/Users/chencong/IdeaProjects/user-behavior-analysis-online/src/main/resources/UserBehavior.csv");
    }
}
